//package com.culturalCenter.dataCenter.controller;
//
//import com.culturalCenter.dataCenter.SparkOnHbaseTest.SparkOnHbaseTest;
//import com.culturalCenter.dataCenter.SparkOnHbaseTest.SparkOnHbaseTest1;
//import com.culturalCenter.dataCenter.Utils.ApiResult;
//import com.culturalCenter.dataCenter.Utils.JwtTokenUtils;
//import com.culturalCenter.dataCenter.globalconfig.filter.CustomFilterInvocationSecurityMetadataSource;
//
//import com.culturalCenter.dataCenter.globalconfig.hbasee.HbaseTemplate;
//import io.swagger.annotations.ApiOperation;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.util.Assert;
//import org.springframework.web.bind.annotation.*;
//
//import javax.servlet.ServletInputStream;
//import javax.servlet.http.HttpServletRequest;
//import java.io.*;
//import java.util.*;
//
//
///**
// * (Users)表控制层
// * http://localhost:9090/v1/users/selectOne
// *
// * @author wulincheng
// * @since 2020-06-14 11:47:22
// */
//@RestController
//@RequestMapping("test")
//@Slf4j
//public class TestController {

//    @Resource
//    private CustomFilterInvocationSecurityMetadataSource customFilterInvocationSecurityMetadataSource;
//
//    @Deprecated
//    @GetMapping("refreshToken")
//    public ApiResult refreshToken(String token) {
//        return ApiResult.instance("200", "成功", JwtTokenUtils.refreshToken(token));
//    }
//
//    @GetMapping("test/queryTest")
//    public ApiResult queryTest() {
//        return ApiResult.instance("b200", "成功");
//    }
//
//
//    @Autowired
//    private HbaseTemplate hbaseTemplate;
//
//
//    @GetMapping("deleteTable")
//    public void createTable() {
////        hbaseTemplate.createTable("users", "personal");
//        hbaseTemplate.deleteTable("users");//删除表
//
////        hbaseTemplate.getRowData("users", "001");
//
//    }
//
//    @GetMapping("insertHbase")
//    public void insertHbase() {
//        //插入数据
//        hbaseTemplate.createTable("users", "personal");
//
//        hbaseTemplate.putData("users", "002", "personal",
//                Arrays.asList("id", "name", "phone"),
//                Arrays.asList(new String[]{"223", "小红", "565765"}));
//        hbaseTemplate.putData("users", "003", "personal",
//                Arrays.asList("id", "name", "phone"),
//                Arrays.asList(new String[]{"223", "小白", "565765"}));
//        hbaseTemplate.putData("users", "004", "personal",
//                Arrays.asList("id", "name", "phone"),
//                Arrays.asList(new String[]{"223", "小丁", "565765"}));
//    }
//
//    @Autowired
//    SparkOnHbaseTest1 sparkOnHbaseTest1;
//    @Autowired
//    SparkOnHbaseTest sparkOnHbaseTest;
//
//    @GetMapping("getHbaseData")
//    public void getHbaseData() throws IOException {
//        sparkOnHbaseTest.getHbase();
////        sparkOnHbaseTest1.getHbase();
//    }
//
//
//    @PostMapping(value = "/upload")
//    @ApiOperation(value = "上传接口", notes = "上传接口")
//    public ApiResult uploadSingle(HttpServletRequest request) throws IOException {
//
//        //保存路径
//        //获取单个系统环境变量
//        String path = System.getenv("FILEUPLOAD");
//
//        ServletInputStream inputStream = request.getInputStream();
//        Assert.notNull(inputStream, "文件不存在");
//        //获取文件上传的真实路径
////        String uploadPath = request.getSession().getServletContext().getRealPath("/");
//        File destfile = new File(path);
//        if (!destfile.exists()) {
//            destfile.mkdirs();
//
//        }
//        //文件新名称
//        String fileNameNew = "test.svg";
//        File f = new File(destfile.getAbsoluteFile() + File.separator + fileNameNew);
//        if (!f.exists()) {
//            OutputStream os = new FileOutputStream(f);
//            BufferedOutputStream bos = new BufferedOutputStream(os);
//
//            byte[] buf = new byte[1024];
//            int length;
//            length = inputStream.read(buf, 0, buf.length);
//
//            while (length != -1) {
//                bos.write(buf, 0, length);
//                length = inputStream.read(buf);
//            }
//            bos.close();
//            os.close();
//            inputStream.close();
//        }
//        return null;
//    }
//
//}
